package transfer

import (
	"github.com/Shopify/sarama"
	"tym.com/LogCollection/elasticsearch"
)

// DisposeToES 从kafka中消费数据并处理发送给es,这里就需要用户处理相关业务发送给es
func DisposeToES(msg *sarama.ConsumerMessage) {
	elasticsearch.InsertES(msg)
}
